package com.talkweb.sendmsg.service;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;

import javax.jms.Destination;
import javax.jms.Queue;

@Service
public class MsgProducer {

	@Autowired
	JmsMessagingTemplate jmsMessagingTemplate;

	@Autowired
	Queue queue;    // 手动注入的queue

	/**
	 * 发送到指定的消息队列
	 * @param destination 指定队列
	 * @param message 发送的消息
	 */
	public void sendMsg(Destination destination, String message) {
		jmsMessagingTemplate.convertAndSend(destination, message);
	}

	/**
	 * 发送到指定的消息队列
	 * @param des 指定队列
	 * @param message 发送的消息
	 */
	public void sendMsg(String des, String message) {
		Destination destination = new ActiveMQQueue(des);
		jmsMessagingTemplate.convertAndSend(destination, message);
	}

	/**
	 * 发送到默认(zh-queue)消息队列去
	 * @param json
	 */
	public void sendMessage(String json) {
		this.jmsMessagingTemplate.convertAndSend(this.queue, json);
	}

}
